package cn.wanda.topologies.bases

import org.apache.spark.SparkContext
import org.apache.spark.sql.SparkSession

trait SparkBatchTopology extends SparkTopology {

  def process(context: SparkContext, session: SparkSession)

}
